package database

import (
	"database/sql"
	"fmt"
	_ "github.com/go-sql-driver/mysql"
)

var DB *sql.DB

func DatabaseInit(dataSourceName string) {
	//用户名:密码@tcp(ip:端口)/数据库的名字
	db, err := sql.Open("mysql", dataSourceName)
	if err != nil {
		fmt.Println(">> 连接数据库失败1,err:", err)
		return
	}
	err = db.Ping() //尝试连接数据库
	if err != nil {
		fmt.Println(">> 连接数据库失败2,err:", err)
		return
	}
	fmt.Println(">> 连接数据库成功")
	DB = db
	return
}
